package cn.com.bluemoon.bd.flink.udf;

import org.apache.flink.table.functions.ScalarFunction;

import java.sql.Timestamp;

public class CurTimeMillsUDF extends ScalarFunction {

    public long eval() {
        return System.currentTimeMillis();
    }

}
